package org.comet.auxiliary.client.liaobei.wss;

import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.timeout.ReadTimeoutHandler;

import java.util.concurrent.TimeUnit;

/**
 * @author wq
 * @date 2019-11-13
 * @description full-compensate-client
 */
public class MyReadTimeoutHandler extends ReadTimeoutHandler {
    public MyReadTimeoutHandler(int timeoutSeconds) {
        super(timeoutSeconds);
    }

    public MyReadTimeoutHandler(long timeout, TimeUnit unit) {
        super(timeout, unit);
    }

    @Override
    protected void readTimedOut(ChannelHandlerContext ctx) throws Exception {
        System.err.println("===read timeout===");
        super.readTimedOut(ctx);
    }
}
